const mysql = require('mysql');
const config = require('../config');
const pool = mysql.createPool(config.dbconfig);

module.exports = {
    query: (sql, params, callback) => {
        pool.getConnection((err1, conn) => {
            if (err1) {
                //出错，所以无结果。故结果为null
                callback(err1, null); //若要获取结果集字段列表的话，则callback(err1,null,null);
            } else {
                conn.query(sql, params, (err2, results, fields) => {
                    if (err2) {
                        callback(err2, null);  //若要获取结果集字段列表的话，则callback(err2,null,null);
                    } else {
                        callback(null, results);  //若要获取结果集字段列表的话，则callback(null,results,fields);
                    }
                    conn.release();
                })
            }
        })

    }
}